package com.ztrue.framework.disruptor;

import com.ztrue.framework.infrastructure.IDistribute;

import java.util.function.Consumer;

/**
 * 表示一个执行分发的消息队列
 *
 * @author zhangw
 * @date 2017/1/18 16:03
 */
public interface IDistributeMessageQueue<M extends IDistribute> {
    /**
     * 发送消息
     *
     * @param consumer
     * @param routingKey
     */
    void send(Consumer<M> consumer, String routingKey);
}
